package com.nota.flink.cdc.pojo.constants;

/**
 * @author 胡超雄
 * @date 2023/12/22 18:16
 * @desc
 */
public class RedisStreamConstants {

    /**
     * 所有关于RedisStream 的前缀
     */
    public static final String KEY_PRE = "stream:";


    /**
     * canal data  key
     */
    public static final String STREAM_KEY_CANAL_DATA = KEY_PRE + "canal_data";

    /**
     * canal_data 消费组
     */
    public static final String GROUP_CANAL_DATA = "group_hcx";

    /**
     * 死信队列
     */
    public static final String DEAD_QUEUE = KEY_PRE + "dead_queue:";

    /**
     * canal data  统计系统 key
     */
    public static final String STREAM_KEY_CANAL_DATA_STAT = KEY_PRE + "canal_data_stat";

    public static final String DELETE = "DELETE";

    public static final String UPDATE = "UPDATE";

    public static final String INSERT = "INSERT";

    /**
     * 死信队列
     */
    public static final String DEAD_LETTER = "canal:dead_letter";

    /**
     * nota 索引前缀
     */
    public static final String NOTA_SEARCH_PRE = "notaIdx:";


    /**
     *  binlog位置
     */
    public static final String BINLOG = "binlog";

}
